package com.stone.customer.console.job;

import com.stone.customer.console.infra.constant.CustomerConsoleConstant;
import com.stone.customer.console.trigger.impl.RedisPointSyncTrigger;
import com.stone.message.adapter.trigger.AbstractCommonReceiverTrigger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 测试触发器job，这是一个定时执行的job
 *
 * @author Mr_wenpan@163.com 2021/07/15 21:41
 */
@Component
public class AbstractCustomerTriggerJobImpl_1 extends AbstractCustomerTriggerJob<String, String> {

    @Autowired
    RedisPointSyncTrigger pointSyncTrigger;

    @Override
    protected String queue() {
        return CustomerConsoleConstant.RedisQueueName.POINT_SYNC_QUEUE;
    }

    @Override
    protected AbstractCommonReceiverTrigger<String, String> getTrigger() {
        return pointSyncTrigger;
    }
}
